package jtcl.tech.kafka.annotation;

import org.springframework.stereotype.Component;

import java.lang.annotation.*;

/**
 * 用于ConsumerBatchListener的实现类<p>
 * 指定groupId
 *
 * @author sjt
 * @since 2021-08-12 13:25
 */
@Target(ElementType.TYPE)
@Retention(RetentionPolicy.RUNTIME)
@Documented
@Component
public @interface KafkaConsumerListener {
    /**
     * 消费者的自定义名称,用于获取指定的Listener<p>
     * 默认为实现类的名称
     */
    String name() default "";

    /**
     * kafka 服务地址
     */
    String bootstrapServers() default "";

    /**
     * 消费者的groupId
     */
    String groupId() default "";

    /**
     * 监听的队列
     */
    String[] topics() default {};


}
